package ringbuffer;
import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.WorkHandler;

public class MsgEventConsumer implements EventHandler<MsgEvent>
{
	@Override
	public void onEvent(MsgEvent event, long sequence, boolean endOfBatch) {
		System.out.println("Event: " + event.getMsg());
	}
}

class MsgEventConsumer_WorkHandler implements WorkHandler<MsgEvent>{
	@Override
	public void onEvent(MsgEvent event) throws Exception {
		System.out.println("Event: " + event.getMsg());
		event.set(event.getMsg()+"#");
	}
}